package observer

/**
 * 观察者
 */
interface Observer<T> {
    /**
     * 被观察者发送消息
     */
    fun onNext(obj: T)

    /**
     * 订阅成功
     */
    fun onSubscribe()

    fun onError(throwable: Throwable)

    fun onComplete()
}